package com.cy.springcloudalibaba.sink;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.messaging.SubscribableChannel;

/**
 * @Description: 自定义sink
 * @ClassName: MySink
 * @Author: chenyu
 * @Date: 2025/3/3 16:31
 */
public interface MySink {
    String INPUT = "inputTX";

    @Input(MySink.INPUT)
    SubscribableChannel inputTX();
}

